package com.woniuxy.email.config;

import com.rabbitmq.client.AMQP;
import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

/**
 * @author yellow Docter
 * @date 2024-10-23
 * @desc 蜗牛创想：www.woniuxy.com
 */
//@Component
public class RabbitMQConfigDirect {

//    @Bean
//    public Queue fanoutQueue1(){
//        return new Queue("fanout.queue1");
//    }
//
//    @Bean
//    public Queue fanoutQueue2(){
//        return new Queue("fanout.queue2");
//    }
//
//    @Bean
//    public Exchange directExchange(){
//        return new DirectExchange("direct.exchange");
//    }
//
//    /**
//     *  bind(fanoutQueue1)   队列
//     * .to(directExchange)   交换机
//     * .with("")             路由进行绑定
//     *
//     * @param fanoutQueue1
//     * @param directExchange
//     * @return
//     */
//    @Bean
//    public Binding binding1(Queue fanoutQueue1,Exchange directExchange){
//
//        // 方法需要返回 Binding ===》 .noargs() 是返回一个 Binding
//        return BindingBuilder.bind(fanoutQueue1).to(directExchange).with("gz").noargs();
//
//    }
//
//    @Bean
//    public Binding binding2(Queue fanoutQueue2,Exchange directExchange){
//        return BindingBuilder.bind(fanoutQueue2).to(directExchange).with("sz").noargs();
//    }
}
